package com.tensai.study.java.newconcept.typereactiveprogram.reactor.mono;

import org.junit.Test;
import reactor.core.publisher.Mono;

/**
 * 测试concatWith两个Mono会发生什么情况
 *
 * @author Tensai
 */
public class ConcatWithTest {

	/**
	 * 两个MONO合并为Flux
	 * 结论： 两个元素
	 */
	@Test
	public void monoAddMono() {
		Mono.just(1).concatWith(Mono.just(2)).subscribe(System.out::println);
	}

	/**
	 * empty+MONO合并为Flux
	 * 结论： 一个元素
	 */
	@Test
	public void emptyAddMono() {
		Mono.empty().concatWith(Mono.just(2)).subscribe(System.out::println);
	}
}
